package com.sun.tool.http;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

/**
 * @Auther: Sunql
 * @Date: 2018/6/11 15:09
 * @Description:
 * 在JDK的java.net包中已经提供了访问HTTP协议的基本功能的类：HttpURLConnection。
 * HttpURLConnection是Java的标准类，它继承自URLConnection，可用于向指定网站发送GET请求、POST请求。
 * 它在URLConnection的基础上提供了如下便捷的方法：
 *
 * int getResponseCode(); // 获取服务器的响应代码。
 * String getResponseMessage(); // 获取服务器的响应消息。
 * String getResponseMethod(); // 获取发送请求的方法。
 * void setRequestMethod(String method); // 设置发送请求的方法。
 */
public class HttpURLConnectionDemo {



/**
 *
 * 功能描述: Get请求 方法
 *
 * @auther: Sunql
 * @date: 2018/6/11 15:23
 * @param: strUrl 请求地址及参数
 * eg:  strUrl = "http://localhost:8080/Servlet/do_login.do?username=test&password=123456"
 * @return: 返回信息
 */
    public String getMethod(String strUrl) {

        String result = null;
        HttpURLConnection connection = null;
        try {

            // 1. 得到访问地址的URL
            URL url = new URL( strUrl);

            // 2. 得到网络访问对象java.net.HttpURLConnection
            connection = (HttpURLConnection) url.openConnection();

            /* 3. 设置请求参数（过期时间，输入、输出流、访问方式），以流的形式进行连接 */
            connection.setDoOutput(false);           // 设置是否向HttpURLConnection输出
            connection.setDoInput(true);             // 设置是否从httpUrlConnection读入
            connection.setRequestMethod("GET");      // 设置请求方式
            connection.setUseCaches(true);           // 设置是否使用缓存
            connection.setInstanceFollowRedirects(true);    // 设置此 HttpURLConnection 实例是否应该自动执行 HTTP 重定向
            connection.setConnectTimeout(3000);         // 设置超时时间
            connection.connect();                       // 连接

            // 4. 得到响应状态码的返回值 responseCode
            int code = connection.getResponseCode();

            // 5. 如果返回值正常，数据在网络中是以流的形式得到服务端返回的数据
            if (code == 200) { // 正常响应

                // 读取返回内容
                StringBuffer buffer = new StringBuffer();
                BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
                String temp;
                while ((temp = reader.readLine()) != null) { // 循环从流中读取
                    buffer.append(temp);
                    buffer.append("\n");
                }
                result = buffer.toString().trim();
                reader.close(); // 关闭流
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

            // 6. 断开连接，释放资源
            connection.disconnect();
        }

        return result;
    }

    /**
     *
     * 功能描述: post 请求示例
     * @auther: Sunql
     * @date: 2018/6/11 15:30
     * @param: strUrl eg: strUrl = "http://localhost:8080/Servlet/do_login.do"
     * @param: params eg: params = "username=test&password=123456";
     * @return:
     */
    public String postMethod(String strUrl, String params) {

        String result = null;
        HttpURLConnection connection = null;
        try {

            URL url = new URL(strUrl);  // 1. 获取访问地址URL

            // 2. 创建HttpURLConnection对象
            connection = (HttpURLConnection) url.openConnection();

            /* 3. 设置请求参数等 */
            connection.setRequestMethod("POST");    // 请求方式
            connection.setConnectTimeout(3000);     // 超时时间
            connection.setDoOutput(true);           // 设置是否输出
            connection.setDoInput(true);            // 设置是否读入
            connection.setUseCaches(false);         // 设置是否使用缓存

            // 设置此 HttpURLConnection 实例是否应该自动执行 HTTP 重定向
            connection.setInstanceFollowRedirects(true);

            // 设置使用标准编码格式编码参数的名-值对
            connection.setRequestProperty("Content-Type",
                    "application/x-www-form-urlencoded");
            connection.connect();                   // 连接

            /* 4. 处理输入输出 */
            // 写入参数到请求中
            OutputStream out = connection.getOutputStream();
            out.write(params.getBytes());
            out.flush();
            out.close();

            // 从连接中读取响应信息
            int code = connection.getResponseCode();
            if (code == 200) {

                StringBuffer buffer = new StringBuffer();

                BufferedReader reader = new BufferedReader(
                        new InputStreamReader(connection.getInputStream()));

                String temp;
                while ((temp = reader.readLine()) != null) {
                    buffer.append(temp);
                    buffer.append("\n");
                }
                result = buffer.toString().trim();
            }

            // 5. 断开连接
            connection.disconnect();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            connection.disconnect();
        }

        // 处理结果
        return result;
    }
}
